package com.mayikt;

import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * @Author: maplefire
 * @Description: 高性能并发队列（ConcurrentLinkedQueue）
 * @Date: 2022/09/02 09:46
 */

public class Test01 {

    public static void main(String[] args) {
        ConcurrentLinkedQueue<String> concurrentLinkedQueue = new ConcurrentLinkedQueue<String>();
        // 非阻塞队列 无界
        concurrentLinkedQueue.offer("张三");
        concurrentLinkedQueue.add("李四");
        // 获取队列（取数超过存放个数，报空）
        System.out.println(concurrentLinkedQueue.peek() + "--" + concurrentLinkedQueue.size()); // 仅取数

        System.out.println(concurrentLinkedQueue.poll() + "--" + concurrentLinkedQueue.size()); // 取数删除

        System.out.println(concurrentLinkedQueue.poll());
        System.out.println(concurrentLinkedQueue.poll());
        System.out.println(concurrentLinkedQueue.poll());
    }
}
